package org.niit.controller

import org.apache.spark.streaming.dstream.DStream
import org.niit.bean.AdClickData
import org.niit.service.{TimeCountService, UserBlackListService}

/**
 * Date:2025/6/3
 * Author：Ys
 * Description:
 */
class UserDataController {

  val userBlackListService = new UserBlackListService()

  val timeCountService = new TimeCountService()

  def dispatch(data:DStream[AdClickData]): Unit = {
    userBlackListService.dataAnalysis(data)

    timeCountService.dataAnalysis(data)
  }

}
